
 <!DOCTYPE HTML>
<html >
<head>
  <meta charset="UTF-8">
  
    <title>线程池ThreadPoolExecuter使用详解 | Typhoon&#39;s code space</title>
    <meta name="viewport" content="width=device-width, initial-scale=1,user-scalable=no">
    
    <meta name="author" content="typhoon">
    

    
    <meta name="description" content="使用过jdk自带线程池或者看过源码的都知道，jdk1.5版本引入了并发包，线程池就是其中一个比较重要 的内容，所谓线程池和连接池以及其他池子一样，其核心概念在于“池”，抛开技术来说，“池”在我们日常生活">
<meta name="keywords" content="ThreadPoolExecuter线程池">
<meta property="og:type" content="article">
<meta property="og:title" content="线程池ThreadPoolExecuter使用详解">
<meta property="og:url" content="http://scorpioaeolus.oschina.io/2018/09/15/线程池ThreadPoolExecuter使用详解/index.html">
<meta property="og:site_name" content="Typhoon&#39;s code space">
<meta property="og:description" content="使用过jdk自带线程池或者看过源码的都知道，jdk1.5版本引入了并发包，线程池就是其中一个比较重要 的内容，所谓线程池和连接池以及其他池子一样，其核心概念在于“池”，抛开技术来说，“池”在我们日常生活">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t1.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t2.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t3.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t4.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t5.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t6.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t7.png">
<meta property="og:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t9.png">
<meta property="og:updated_time" content="2018-09-15T05:27:22.337Z">
<meta name="twitter:card" content="summary">
<meta name="twitter:title" content="线程池ThreadPoolExecuter使用详解">
<meta name="twitter:description" content="使用过jdk自带线程池或者看过源码的都知道，jdk1.5版本引入了并发包，线程池就是其中一个比较重要 的内容，所谓线程池和连接池以及其他池子一样，其核心概念在于“池”，抛开技术来说，“池”在我们日常生活">
<meta name="twitter:image" content="http://scorpioaeolus.oschina.io/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t1.png">

    
    <link rel="alternative" href="/atom.xml" title="Typhoon&#39;s code space" type="application/atom+xml">
    
    
    <link rel="icon" href="/typhoon/img/java.png">
    
    
    <link rel="apple-touch-icon" href="/typhoon/img/jacman.jpg">
    <link rel="apple-touch-icon-precomposed" href="/typhoon/img/jacman.jpg">
    
    <link rel="stylesheet" href="/typhoon/css/style.css">
</head>

  <body>
    <header>
      
<div>
		
			<div id="imglogo">
				<a href="/typhoon/"><img src="/typhoon/img/java.png" alt="Typhoon&#39;s code space" title="Typhoon&#39;s code space"/></a>
			</div>
			
			<div id="textlogo">
				<h1 class="site-name"><a href="/typhoon/" title="Typhoon&#39;s code space">Typhoon&#39;s code space</a></h1>
				<h2 class="blog-motto"></h2>
			</div>
			<div class="navbar"><a class="navbutton navmobile" href="#" title="Menu">
			</a></div>
			<nav class="animated">
				<ul>
					<ul>
					 
						<li><a href="/typhoon/">主页</a></li>
					
						<li><a href="/typhoon/archives">归档</a></li>
					
						<li><a href="/typhoon/about">关于</a></li>
					
					<li>
 					
					<form class="search" action="//google.com/search" method="get" accept-charset="utf-8">
						<label>Search</label>
						<input type="search" id="search" name="q" autocomplete="off" maxlength="20" placeholder="Search" />
						<input type="hidden" name="q" value="site:scorpioaeolus.oschina.io">
					</form>
					
					</li>
				</ul>
			</nav>			
</div>
    </header>
    <div id="container">
      <div id="main" class="post" itemscope itemprop="blogPost">
  
	<article itemprop="articleBody"> 
		<header class="article-info clearfix">
  <h1 itemprop="name">
    
      <a href="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/" title="线程池ThreadPoolExecuter使用详解" itemprop="url">线程池ThreadPoolExecuter使用详解</a>
  </h1>
  <p class="article-author">By
       
		<a href="/typhoon/about" title="typhoon" target="_blank" itemprop="author">typhoon</a>
		
  <p class="article-time">
    <time datetime="2018-09-15T01:27:37.000Z" itemprop="datePublished"> Published 2018-09-15</time>
    
  </p>
</header>
	<div class="article-content">
		
		<div id="toc" class="toc-article">
			<strong class="toc-title">Contents</strong>
		
			<ol class="toc"><li class="toc-item toc-level-5"><a class="toc-link" href="#常见使用方式分析"><span class="toc-number">1.</span> <span class="toc-text">常见使用方式分析</span></a></li><li class="toc-item toc-level-5"><a class="toc-link" href="#线程池原理分析"><span class="toc-number">2.</span> <span class="toc-text">线程池原理分析</span></a></li></ol>
		
		</div>
		
		<pre><code>    使用过jdk自带线程池或者看过源码的都知道，jdk1.5版本引入了并发包，线程池就是其中一个比较重要
的内容，所谓线程池和连接池以及其他池子一样，其核心概念在于“池”，抛开技术来说，“池”在我们日常生活
</code></pre>  <a id="more"></a>
<pre><code>中其实就是容器的概念，比如水池等等，水池的目的是为了下雨了可以蓄水，干旱了可以用来灌溉，那么应用
编程中的“池”可以理解成缓存，用一张图来更直观的理解“池”的概念和作用：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t1.png" alt="threadpool" title="threadpool">
<pre><code>    图中圆角图分别是线程池和连接池，应用程序需要用到多线程的时候，优先去线程池取，然后处理业务逻辑，
处理完了之后把线程归还到线程池，当应用程序访问数据库的时候，优先去连接池获取连接，然后操作数据库，
操作完成之后把连接归还到连接池。
    从上述描述中，对线程池有了大概的概念，接下来我们详细分析一下jdk自带线程池的用法和实现原理。
</code></pre><h5 id="常见使用方式分析"><a href="#常见使用方式分析" class="headerlink" title="常见使用方式分析"></a>常见使用方式分析</h5><pre><code>线程池的常用使用方式是：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div></pre></td><td class="code"><pre><div class="line">ExecutorService executorService =  Executors.newXXXThreadPool();</div></pre></td></tr></table></figure>
<pre><code>java通过Executors提供了常用的四种线程池：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t2.png" alt="threadpool" title="threadpool">
<pre><code>    四种线程池分配是：
①newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，
 则新建线程。
②newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
③newScheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行。
④newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照
 指定顺序(FIFO, LIFO, 优先级)执行。
    然后我们分析一下每种线程池的用法和原理：
</code></pre><p><strong>newCachedThreadPool线程池</strong></p>
<pre><code>    创建一个线程池，根据需要创建新线程，但将在可用时重用先前构建的线程。这些池通常将提高执行许多短期
异步任务的程序的性能。如果可用，对execute方法的调用将重用先前构造的线程。如果没有现有线程可用，则将
创建新线程并将其添加到池中。未使用六十秒的线程被终止并从缓存中移除。因此，一个长期闲置的池不会消耗任
何资源。可以使用ThreadPoolExecutor构造函数创建具有相似属性但不同细节（例如，超时参数）的线程池。
    newCachedThreadPool线程池的常用使用方式如下： 
</code></pre><figure class="highlight plain"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div><div class="line">9</div><div class="line">10</div><div class="line">11</div><div class="line">12</div></pre></td><td class="code"><pre><div class="line">public static void main(String[] args) &#123;</div><div class="line">    ExecutorService cachedThreadPool = Executors.newCachedThreadPool();</div><div class="line">   for (int i = 0; i &lt; 10; i++) &#123;</div><div class="line">    final int index = i;</div><div class="line">    try &#123;</div><div class="line">	Thread.sleep(index * 1000);</div><div class="line">    &#125; catch (InterruptedException e) &#123;</div><div class="line">	e.printStackTrace();</div><div class="line">    &#125;</div><div class="line">    cachedThreadPool.execute(() -&gt; System.out.println(index));</div><div class="line">&#125;</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>    由于是缓存线程池，线程池为无限大，当执行第二个任务时第一个任务已经完成，会复用执行第一个任务的线程，
而不用每次新建线程，如果任务比较耗时，第二个任务来的时候第一个还没执行完，会新建线程。
    特别注意的是，如果使用newCachedThreadPool线程池，突发访问量特别大，有可能导致内存溢出，改造上述代码
 并运行：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div><div class="line">9</div><div class="line">10</div><div class="line">11</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">ExecutorService cachedThreadPool = Executors.newCachedThreadPool();</div><div class="line"><span class="keyword">for</span> (<span class="keyword">int</span> i = <span class="number">1</span>; i &lt; <span class="number">10000</span>; i++)</div><div class="line">    cachedThreadPool.submit(() -&gt; &#123;</div><div class="line">	<span class="keyword">try</span> &#123;</div><div class="line">	    Thread.sleep(<span class="number">5000</span>);</div><div class="line">	&#125; <span class="keyword">catch</span> (InterruptedException e) &#123;</div><div class="line">	    e.printStackTrace();</div><div class="line">	&#125;</div><div class="line">    &#125;);</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>运行后发生om错误：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t3.png" alt="threadpool" title="threadpool">
<pre><code>    所以一定要慎用newCachedThreadPool线程池，或者使用的时候不适用其默认提供的方式，而是基于ThreadPoolExecutor
自己构造。
</code></pre><p><strong>newFixedThreadPool线程池</strong></p>
<pre><code>    创建一个指定线程数量从无界队列共享任务的线程池，在任何时候，至多{nThreads}线程将是活动的处理任务。如果在
所有线程都处于活动状态时提交额外的任务，则它们将在队列中等待，直到线程可用。如果任何线程在关闭之前由于执行过
程中的失败而终止，那么如果需要执行后续任务，将替换一个新的线程。池中的线程将存在，直到显式调用shutdown关闭为
止。
    newFixedThreadPool线程池常用使用方式如下：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div><div class="line">9</div><div class="line">10</div><div class="line">11</div><div class="line">12</div><div class="line">13</div><div class="line">14</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">ExecutorService fixedThreadPool = Executors.newFixedThreadPool(<span class="number">3</span>);</div><div class="line"><span class="keyword">for</span> (<span class="keyword">int</span> i = <span class="number">0</span>; i &lt; <span class="number">10</span>; i++) &#123;</div><div class="line">    <span class="keyword">final</span> <span class="keyword">int</span> index = i;</div><div class="line">    fixedThreadPool.execute(() -&gt; &#123;</div><div class="line">	<span class="keyword">try</span> &#123;</div><div class="line">	    System.out.println(index);</div><div class="line">	    Thread.sleep(<span class="number">2000</span>);</div><div class="line">	&#125; <span class="keyword">catch</span> (InterruptedException e) &#123;</div><div class="line">	    e.printStackTrace();</div><div class="line">	&#125;</div><div class="line">    &#125;);</div><div class="line">&#125;</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>    因为线程池大小为3，每个任务输出index后sleep 2秒，所以每两秒打印3个数字。定长线程池的大小最好根据系统资源进行
设置。如Runtime.getRuntime().availableProcessors()。
    需要注意的是，newFixedThreadPool线程池使用的队列也是无界队列LinkedBlockingQueue，源码如下：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> ExecutorService <span class="title">newFixedThreadPool</span><span class="params">(<span class="keyword">int</span> nThreads)</span> </span>&#123;</div><div class="line"><span class="keyword">return</span> <span class="keyword">new</span> ThreadPoolExecutor(nThreads, nThreads,</div><div class="line">			      <span class="number">0L</span>, TimeUnit.MILLISECONDS,</div><div class="line">			      <span class="keyword">new</span> LinkedBlockingQueue&lt;Runnable&gt;());</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>    所以使用的时候不会因为像newCachedThreadPool线程池创建过多的线程导致om错误，但是可能会因为突发访问量特别大，导
致newFixedThreadPool线程池中活跃线程处理不过来，然后任务大量堆积在队列中，而LinkedBlockingQueue队列又是无界的，所
以会因为任务大量推挤到LinkedBlockingQueue导致om错误。改造上述代码并运行：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div><div class="line">9</div><div class="line">10</div><div class="line">11</div><div class="line">12</div><div class="line">13</div><div class="line">14</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">ExecutorService fixedThreadPool = Executors.newFixedThreadPool(<span class="number">3</span>);</div><div class="line"><span class="keyword">for</span> (<span class="keyword">int</span> i = <span class="number">0</span>; i &lt; <span class="number">50000</span>; i++) &#123;</div><div class="line">    <span class="keyword">final</span> <span class="keyword">int</span> index = i;</div><div class="line">    fixedThreadPool.submit(() -&gt; &#123;</div><div class="line">	<span class="keyword">try</span> &#123;</div><div class="line">	    System.out.println(index);</div><div class="line">	    Thread.sleep(<span class="number">10000</span>);</div><div class="line">	&#125; <span class="keyword">catch</span> (InterruptedException e) &#123;</div><div class="line">	    e.printStackTrace();</div><div class="line">	&#125;</div><div class="line">    &#125;);</div><div class="line">&#125;</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>运行程序也出现了om错误：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t4.png" alt="threadpool" title="threadpool">
<pre><code>    在使用newFixedThreadPool线程池的时候，也要评估访问量峰值来设置活跃线程的大小，另外在互联网行业，流量变化的
不可预知性太强，所以不建议使用默认的方式创建newFixedThreadPool线程池，而是使用原生的ThreadPoolExecutor构造方法
创建线程池，根据业务需要指定活跃线程数和任务队列长度(不建议使用无界队列)。
</code></pre><p><strong>newScheduledThreadPool</strong></p>
<pre><code>    创建一个在给定延迟之后执行命令或者定时执行命令的调度线程池，{corePoolSize}是保留在线程池中的活跃线程数量，
即使是空闲的也不会回收。
    newScheduledThreadPool线程池常用使用方式如下：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">    ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(<span class="number">5</span>);</div><div class="line">    scheduledThreadPool.scheduleWithFixedDelay(() -&gt;System.out.println(<span class="string">"delay 3 seconds"</span>),<span class="number">1</span>,<span class="number">3</span>,TimeUnit.SECONDS);</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>上述代码的作用是延迟1秒执行，并且每3秒执行一次，其实起到一个简易调度的功能。
使用调度线程池需要注意的是，使用Executors创建的调度线程池默认任务队列DelayedWorkQueue是无界队列：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="title">ScheduledThreadPoolExecutor</span><span class="params">(<span class="keyword">int</span> corePoolSize)</span> </span>&#123;</div><div class="line">    <span class="keyword">super</span>(corePoolSize, Integer.MAX_VALUE, <span class="number">0</span>, NANOSECONDS,</div><div class="line">      <span class="keyword">new</span> DelayedWorkQueue());</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>所以使用调度线程池的时候也要注意，当并发调度任务比较大的时候，也可能出现om错误。改造测试代码：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">    ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(<span class="number">5</span>);</div><div class="line">    <span class="keyword">for</span>(<span class="keyword">int</span> i = <span class="number">0</span>;i &lt; <span class="number">10000</span>;i ++) &#123;</div><div class="line">         scheduledThreadPool.scheduleWithFixedDelay(() -&gt;System.out.println(<span class="string">"delay 3 seconds"</span>),<span class="number">1</span>,<span class="number">3</span>,TimeUnit.SECONDS);</div><div class="line">    &#125;</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>运行程序也出现了内存溢出：        
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t5.png" alt="threadpool" title="threadpool">
<pre><code>    这种场景我们遇到的比较少，一般不需要关心(调度大多由调度中间件完成)，如果真的遇到比较特殊的场景，也强烈建议
使用ThreadPoolExecutor原生的构造方法创建线程池，指定队列类型和长度。
</code></pre><p><strong>newSingleThreadExecutor线程池</strong></p>
<pre><code>    创建一个线程池(执行器)，它使用一个从无界队列中操作的单个工作线程。（但是，需要注意的是，如果该单个线程在关闭
之前由于执行过程中的失败而终止，那么如果需要执行后续任务，将替换一个新的线程。）任务被保证顺序执行，并且在任何给
定时间都不会有多于一个任务是活动的。与其他等价的{@code newFixedThreadPool(1)}不同，返回的执行器保证不会重新配置来
使用其他线程。
    newSingleThreadExecutor线程池的使用方式如下：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div><div class="line">9</div><div class="line">10</div><div class="line">11</div><div class="line">12</div><div class="line">13</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();</div><div class="line"><span class="keyword">for</span> (<span class="keyword">int</span> i = <span class="number">0</span>; i &lt; <span class="number">10</span>; i++) &#123;</div><div class="line">    <span class="keyword">final</span> <span class="keyword">int</span> index = i;</div><div class="line">    singleThreadExecutor.execute(() -&gt; &#123;</div><div class="line">	<span class="keyword">try</span> &#123;</div><div class="line">	System.out.println(index);</div><div class="line">	Thread.sleep(<span class="number">2000</span>);</div><div class="line">    &#125; <span class="keyword">catch</span> (InterruptedException e) &#123;</div><div class="line">	e.printStackTrace();</div><div class="line">    &#125;&#125;);</div><div class="line">&#125;</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>依次输出结果，也就是顺序的执行每个任务。
像前边几种线程池一样，newSingleThreadExecutor线程池默认也是使用无界队列存储任务，源码如下：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> ExecutorService <span class="title">newSingleThreadExecutor</span><span class="params">()</span> </span>&#123;</div><div class="line"><span class="keyword">return</span> <span class="keyword">new</span> FinalizableDelegatedExecutorService</div><div class="line">    (<span class="keyword">new</span> ThreadPoolExecutor(<span class="number">1</span>, <span class="number">1</span>,</div><div class="line">			    <span class="number">0L</span>, TimeUnit.MILLISECONDS,</div><div class="line">			    <span class="keyword">new</span> LinkedBlockingQueue&lt;Runnable&gt;()));</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>当突发请求量比较大的时候，任务队列过大也会导致om错误。改造测试代码：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div><div class="line">9</div><div class="line">10</div><div class="line">11</div><div class="line">12</div><div class="line">13</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> <span class="keyword">void</span> <span class="title">main</span><span class="params">(String[] args)</span> </span>&#123;</div><div class="line">ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();</div><div class="line"><span class="keyword">for</span> (<span class="keyword">int</span> i = <span class="number">0</span>; i &lt; <span class="number">100000</span>; i++) &#123;</div><div class="line">    <span class="keyword">final</span> <span class="keyword">int</span> index = i;</div><div class="line">    singleThreadExecutor.execute(() -&gt; &#123;</div><div class="line">	<span class="keyword">try</span> &#123;</div><div class="line">	System.out.println(index);</div><div class="line">	Thread.sleep(<span class="number">2000</span>);</div><div class="line">    &#125; <span class="keyword">catch</span> (InterruptedException e) &#123;</div><div class="line">	e.printStackTrace();</div><div class="line">    &#125;&#125;);</div><div class="line">&#125;</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>运行测试代码，发现报了内存溢出：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t6.png" alt="threadpool" title="threadpool">
<pre><code>    单线程线程池的应用场景一般是需要顺序处理的业务，并发量不会太多，也不会有人创建单线程的线程池
来处理高并发请求，但是使用的时候也需要注意。

    从以上四种线程池的使用以及原理分析可以总结出比较重要的两点：
</code></pre><p><strong>1）</strong> 慎用缓存线程池，如果并发量大会使线程创建过多导致jvm内存溢出。<br><strong>2）</strong>    慎用无界队列，使用除缓存线程池之外的其他三种线程池，如果并发量比较大，都会遇到任务大量堆积到队列中<br>        导致om错误。</p>
<h5 id="线程池原理分析"><a href="#线程池原理分析" class="headerlink" title="线程池原理分析"></a>线程池原理分析</h5><pre><code>    从上边四种线程池的使用和存在的问题分析，想必我们对jdk自带线程池有了比较深刻的理解，接着我们对
线程池的实现原理做一下剖析。以newFixedThreadPool线程池为例，参照源码分析一下其实现原理。
</code></pre><p><strong>newFixedThreadPool</strong></p>
<figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="keyword">static</span> ExecutorService <span class="title">newFixedThreadPool</span><span class="params">(<span class="keyword">int</span> nThreads)</span> </span>&#123;</div><div class="line"><span class="keyword">return</span> <span class="keyword">new</span> ThreadPoolExecutor(nThreads, nThreads,</div><div class="line">			      <span class="number">0L</span>, TimeUnit.MILLISECONDS,</div><div class="line">			      <span class="keyword">new</span> LinkedBlockingQueue&lt;Runnable&gt;());</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>newFixedThreadPool方法调用了5个参数的构造器，代码中有几个比较重要的参数：
</code></pre><p><strong>1）</strong>       corePoolSize: 是核心线程数，此处传入nThreads(线程池一直持有的线程数量，就算线程空闲)<br><strong>2）</strong>    maximumPoolSize: 是线程池中拥有的最大线程数量，此处传入nThreads，核心线程和最大线程一样(避免了不停<br>           销毁线程和新建线程带来的开销)<br><strong>3）</strong>    keepAliveTime:当线程池中线程数量大于corePoolSize时，大于核心线程数量部分线程空闲时存活时间，此处传入0<br><strong>4）</strong>    unit：存活时间的单位，此处传入TimeUnit.MILLISECONDS毫秒<br><strong>5）</strong>    workQueue：任务队列，如果新提交的任务无法立即被线程处理，那么将会放入任务队列，此处传入LinkedBlockingQueue<br>           无界队列</p>
<pre><code>接着看源码，又调用了7个参数的构造方法：
</code></pre><figure class="highlight java"><table><tr><td class="gutter"><pre><div class="line">1</div><div class="line">2</div><div class="line">3</div><div class="line">4</div><div class="line">5</div><div class="line">6</div><div class="line">7</div><div class="line">8</div></pre></td><td class="code"><pre><div class="line"><span class="function"><span class="keyword">public</span> <span class="title">ThreadPoolExecutor</span><span class="params">(<span class="keyword">int</span> corePoolSize,</span></span></div><div class="line">		      <span class="keyword">int</span> maximumPoolSize,</div><div class="line">		      <span class="keyword">long</span> keepAliveTime,</div><div class="line">		      TimeUnit unit,</div><div class="line">		      BlockingQueue&lt;Runnable&gt; workQueue) &#123;</div><div class="line"><span class="keyword">this</span>(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,</div><div class="line">     Executors.defaultThreadFactory(), defaultHandler);</div><div class="line">&#125;</div></pre></td></tr></table></figure>
<pre><code>该构造方法比前边多了两个参数：
</code></pre><p><strong>6）</strong>       threadFactory：创建线程使用的线程工厂，此处使用的是默认线程工厂Executors.defaultThreadFactory()<br><strong>7）</strong>       handler：当线程池无法处理新提交的任务时的拒绝策略，此处使用默认的AbortPolicy</p>
<pre><code>newFixedThreadPool线程池处理请求时的模型大致如下图：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t7.png" alt="threadpool" title="threadpool">
<pre><code>当线程池接收到新的任务的时候处理流程如下：
</code></pre><img src="/typhoon/2018/09/15/线程池ThreadPoolExecuter使用详解/t9.png" alt="threadpool" title="threadpool">
<pre><code>    核心思想就是，线程池新接收任务后，如果当前线程池的线程数量小于核心线程池数量，无论如何都会创建一个
线程去处理任务，如果线程池中的线程到达核心线程数量但是有空闲，那么就把任务提交到任务队列，如果线程数到
达核心线程数量，并且没有空闲，就尝试新建一个线程处理任务，如果当前线程数量到达最大线程数量，但是有线程
空闲，那就提交到任务队列，如果线程数量达到最大线程数，并且任务队列已满，那么就使用拒绝策略拒绝任务。
</code></pre>  
	</div>
		<footer class="article-footer clearfix">
<div class="article-catetags">

<div class="article-categories">
  <span></span>
  <a class="article-category-link" href="/typhoon/categories/java性能优化/">java性能优化</a>
</div>


  <div class="article-tags">
  
  <span></span> <a href="/typhoon/tags/ThreadPoolExecuter线程池/">ThreadPoolExecuter线程池</a>
  </div>

</div>



	<div class="article-share" id="share">
	
	  <div data-url="http://scorpioaeolus.oschina.io/2018/09/15/线程池ThreadPoolExecuter使用详解/" data-title="线程池ThreadPoolExecuter使用详解 | Typhoon&#39;s code space" data-tsina="null" class="share clearfix">
	  </div>
	
	</div>


</footer>

   	       
	</article>
	
<nav class="article-nav clearfix">
 
 <div class="prev" >
 <a href="/typhoon/2018/09/15/BeanPostProcessor原理及应用场景/" title="spring扩展点BeanPostProcessor">
  <strong>上一篇：</strong><br/>
  <span>
  spring扩展点BeanPostProcessor</span>
</a>
</div>


<div class="next">
<a href="/typhoon/2018/09/14/设计模式-责任链模式详解/"  title="设计模式----责任链模式详解">
 <strong>下一篇：</strong><br/> 
 <span>设计模式----责任链模式详解
</span>
</a>
</div>

</nav>

	


</div>  
      <div class="openaside"><a class="navbutton" href="#" title="Show Sidebar"></a></div>

  <div id="toc" class="toc-aside">
  <strong class="toc-title">Contents</strong>
 
 <ol class="toc"><li class="toc-item toc-level-5"><a class="toc-link" href="#常见使用方式分析"><span class="toc-number">1.</span> <span class="toc-text">常见使用方式分析</span></a></li><li class="toc-item toc-level-5"><a class="toc-link" href="#线程池原理分析"><span class="toc-number">2.</span> <span class="toc-text">线程池原理分析</span></a></li></ol>
 
  </div>

<div id="asidepart">
<div class="closeaside"><a class="closebutton" href="#" title="Hide Sidebar"></a></div>
<aside class="clearfix">

  


  
<div class="categorieslist">
	<p class="asidetitle">Categories</p>
		<ul>
		
		  
			<li><a href="/typhoon/categories/dubbo/" title="dubbo">dubbo<sup>8</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/java性能优化/" title="java性能优化">java性能优化<sup>17</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/java源码分析/" title="java源码分析">java源码分析<sup>1</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/motan/" title="motan">motan<sup>2</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/spring/" title="spring">spring<sup>11</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/springboot/" title="springboot">springboot<sup>28</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/springmvc/" title="springmvc">springmvc<sup>1</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/容器/" title="容器">容器<sup>1</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/工具/" title="工具">工具<sup>7</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/性能优化/" title="性能优化">性能优化<sup>5</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/架构/" title="架构">架构<sup>8</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/案例分析/" title="案例分析">案例分析<sup>13</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/缓存/" title="缓存">缓存<sup>4</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/设计模式/" title="设计模式">设计模式<sup>3</sup></a></li>
		  
		
		  
			<li><a href="/typhoon/categories/面试题/" title="面试题">面试题<sup>1</sup></a></li>
		  
		
		</ul>
</div>


  
<div class="tagslist">
	<p class="asidetitle">Tags</p>
		<ul class="clearfix">
		
			
				<li><a href="/typhoon/tags/springboot/" title="springboot">springboot<sup>28</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/java性能优化/" title="java性能优化">java性能优化<sup>9</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/限流/" title="限流">限流<sup>3</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/Spring5/" title="Spring5">Spring5<sup>3</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/设计模式/" title="设计模式">设计模式<sup>3</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/案例分析/" title="案例分析">案例分析<sup>2</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/性能优化/" title="性能优化">性能优化<sup>2</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/Spring/" title="Spring">Spring<sup>2</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/dubbo/" title="dubbo">dubbo<sup>2</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/分页/" title="分页">分页<sup>2</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/并发/" title="并发">并发<sup>2</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/异常拦截/" title="异常拦截">异常拦截<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/dubbo分布式事务/" title="dubbo分布式事务">dubbo分布式事务<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/自带图片/" title="自带图片">自带图片<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/svn导出mvn项目/" title="svn导出mvn项目">svn导出mvn项目<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/dubbo过滤器/" title="dubbo过滤器">dubbo过滤器<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/排序性能对比/" title="排序性能对比">排序性能对比<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/ListenableFuture/" title="ListenableFuture">ListenableFuture<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/PropertyChangeListener/" title="PropertyChangeListener">PropertyChangeListener<sup>1</sup></a></li>
			
		
			
				<li><a href="/typhoon/tags/jdbcTemplate高可用/" title="jdbcTemplate高可用">jdbcTemplate高可用<sup>1</sup></a></li>
			
		
		</ul>
</div>


  <div class="linkslist">
  <p class="asidetitle">Links</p>
    <ul>
        
          <li>
            
            	<a href="https://coderq.com" target="_blank" title="一个面向程序员交流分享的新一代社区">码农圈</a>
            
          </li>
        
          <li>
            
            	<a href="http://wuchong.me" target="_blank" title="Jark&#39;s Blog">Jark&#39;s Blog</a>
            
          </li>
        
    </ul>
</div>

  


  <div class="rsspart">
	<a href="/atom.xml" target="_blank" title="rss">RSS</a>
</div>

  <div class="weiboshow">
  <p class="asidetitle">Weibo</p>
    <iframe width="100%" height="119" class="share_self"  frameborder="0" scrolling="no" src="http://widget.weibo.com/weiboshow/index.php?language=&width=0&height=119&fansRow=2&ptype=1&speed=0&skin=9&isTitle=1&noborder=1&isWeibo=0&isFans=0&uid=null&verifier=b3593ceb&dpc=1"></iframe>
</div>


</aside>
</div>
    </div>
    <footer><div id="footer" >
	
	<div class="line">
		<span></span>
		<div class="author"></div>
	</div>
	
	
	<section class="info">
		<p> Hello ,I&#39;m a java coder. <br/>
			This is my blog,believe it or not.</p>
	</section>
	 
	<div class="social-font" class="clearfix">
		
		
		
		
		
		
		
		
		
		
		<a href="mailto:ScorpioAeolus@163.com" target="_blank" class="icon-email" title="Email Me"></a>
		
	</div>
			
		

		<p class="copyright">
		Powered by <a href="http://hexo.io" target="_blank" title="hexo">hexo</a> and Theme by <a href="https://github.com/wuchong/jacman" target="_blank" title="Jacman">Jacman</a> © 2019 
		
		<a href="/typhoon/about" target="_blank" title="typhoon">typhoon</a>
		
		
		</p>
</div>
</footer>
    <script src="/typhoon/js/jquery-2.0.3.min.js"></script>
<script src="/typhoon/js/jquery.imagesloaded.min.js"></script>
<script src="/typhoon/js/gallery.js"></script>
<script src="/typhoon/js/jquery.qrcode-0.12.0.min.js"></script>

<script type="text/javascript">
$(document).ready(function(){ 
  $('.navbar').click(function(){
    $('header nav').toggleClass('shownav');
  });
  var myWidth = 0;
  function getSize(){
    if( typeof( window.innerWidth ) == 'number' ) {
      myWidth = window.innerWidth;
    } else if( document.documentElement && document.documentElement.clientWidth) {
      myWidth = document.documentElement.clientWidth;
    };
  };
  var m = $('#main'),
      a = $('#asidepart'),
      c = $('.closeaside'),
      o = $('.openaside');
  c.click(function(){
    a.addClass('fadeOut').css('display', 'none');
    o.css('display', 'block').addClass('fadeIn');
    m.addClass('moveMain');
  });
  o.click(function(){
    o.css('display', 'none').removeClass('beforeFadeIn');
    a.css('display', 'block').removeClass('fadeOut').addClass('fadeIn');      
    m.removeClass('moveMain');
  });
  $(window).scroll(function(){
    o.css("top",Math.max(80,260-$(this).scrollTop()));
  });
  
  $(window).resize(function(){
    getSize(); 
    if (myWidth >= 1024) {
      $('header nav').removeClass('shownav');
    }else{
      m.removeClass('moveMain');
      a.css('display', 'block').removeClass('fadeOut');
      o.css('display', 'none');
      
      $('#toc.toc-aside').css('display', 'none');
        
    }
  });
});
</script>

<script type="text/javascript">
$(document).ready(function(){ 
  var ai = $('.article-content>iframe'),
      ae = $('.article-content>embed'),
      t  = $('#toc'),
      ta = $('#toc.toc-aside'),
      o  = $('.openaside'),
      c  = $('.closeaside');
  if(ai.length>0){
    ai.wrap('<div class="video-container" />');
  };
  if(ae.length>0){
   ae.wrap('<div class="video-container" />');
  };
  c.click(function(){
    ta.css('display', 'block').addClass('fadeIn');
  });
  o.click(function(){
    ta.css('display', 'none');
  });
  $(window).scroll(function(){
    ta.css("top",Math.max(140,320-$(this).scrollTop()));
  });
});
</script>


<script type="text/javascript">
$(document).ready(function(){ 
  var $this = $('.share'),
      url = $this.attr('data-url'),
      encodedUrl = encodeURIComponent(url),
      title = $this.attr('data-title'),
      tsina = $this.attr('data-tsina'),
      description = $this.attr('description');
  var html = [
  '<div class="hoverqrcode clearfix"></div>',
  '<a class="overlay" id="qrcode"></a>',
  '<a href="https://www.facebook.com/sharer.php?u=' + encodedUrl + '" class="article-share-facebook" target="_blank" title="Facebook"></a>',
  '<a href="https://twitter.com/intent/tweet?url=' + encodedUrl + '" class="article-share-twitter" target="_blank" title="Twitter"></a>',
  '<a href="#qrcode" class="article-share-qrcode" title="微信"></a>',
  '<a href="http://widget.renren.com/dialog/share?resourceUrl=' + encodedUrl + '&srcUrl=' + encodedUrl + '&title=' + title +'" class="article-share-renren" target="_blank" title="人人"></a>',
  '<a href="http://service.weibo.com/share/share.php?title='+title+'&url='+encodedUrl +'&ralateUid='+ tsina +'&searchPic=true&style=number' +'" class="article-share-weibo" target="_blank" title="微博"></a>',
  '<span title="Share to"></span>'
  ].join('');
  $this.append(html);

  $('.hoverqrcode').hide();

  var myWidth = 0;
  function updatehoverqrcode(){
    if( typeof( window.innerWidth ) == 'number' ) {
      myWidth = window.innerWidth;
    } else if( document.documentElement && document.documentElement.clientWidth) {
      myWidth = document.documentElement.clientWidth;
    };
    var qrsize = myWidth > 1024 ? 200:100;
    var options = {render: 'image', size: qrsize, fill: '#2ca6cb', text: url, radius: 0.5, quiet: 1};
    var p = $('.article-share-qrcode').position();
    $('.hoverqrcode').empty().css('width', qrsize).css('height', qrsize)
                          .css('left', p.left-qrsize/2+20).css('top', p.top-qrsize-10)
                          .qrcode(options);
  };
  $(window).resize(function(){
    $('.hoverqrcode').hide();
  });
  $('.article-share-qrcode').click(function(){
    updatehoverqrcode();
    $('.hoverqrcode').toggle();
  });
  $('.article-share-qrcode').hover(function(){}, function(){
      $('.hoverqrcode').hide();
  });
});   
</script>









<link rel="stylesheet" href="/typhoon/fancybox/jquery.fancybox.css" media="screen" type="text/css">
<script src="/typhoon/fancybox/jquery.fancybox.pack.js"></script>
<script type="text/javascript">
$(document).ready(function(){ 
  $('.article-content').each(function(i){
    $(this).find('img').each(function(){
      if ($(this).parent().hasClass('fancybox')) return;
      var alt = this.alt;
      if (alt) $(this).after('<span class="caption">' + alt + '</span>');
      $(this).wrap('<a href="' + this.src + '" title="' + alt + '" class="fancybox"></a>');
    });
    $(this).find('.fancybox').each(function(){
      $(this).attr('rel', 'article' + i);
    });
  });
  if($.fancybox){
    $('.fancybox').fancybox();
  }
}); 
</script>



<!-- Analytics Begin -->



<script>
var _hmt = _hmt || [];
(function() {
  var hm = document.createElement("script");
  hm.src = "//hm.baidu.com/hm.js?e6d1f421bbc9962127a50488f9ed37d1";
  var s = document.getElementsByTagName("script")[0]; 
  s.parentNode.insertBefore(hm, s);
})();
</script>



<!-- Analytics End -->

<!-- Totop Begin -->

	<div id="totop">
	<a title="Back to Top"><img src="/typhoon/img/scrollup.png"/></a>
	</div>
	<script src="/typhoon/js/totop.js"></script>

<!-- Totop End -->

<!-- MathJax Begin -->
<!-- mathjax config similar to math.stackexchange -->


<!-- MathJax End -->

<!-- Tiny_search Begin -->

<!-- Tiny_search End -->

  </body>
</html>
